package producer;

import base.TopicModule;

/**
 * @author : zGame
 * @version V1.0
 * @Project: rokectmqprac
 * @Package producer
 * @Description: game2game 通用producer
 * @date Date : 2022年01月10日 18:32
 */
public class NormalProducer extends ProducerUtil{
    
    @Override
    public void propertySet() {
        producer.setNamesrvAddr("localhost:9876");
        //设置为偶数 这里一个tag 一个实例. 类似于把不同的producer 生产的消息都放在同一queue当中
        producer.setDefaultTopicQueueNums(4) ;
    }
    
    @Override
    public TopicModule getTopicModule() {
        return TopicModule.GAME;
    }
    
    private static class DEFAULT{
        private static final NormalProducer provider = new NormalProducer();
    }
    public static NormalProducer getInstance(){
        return DEFAULT.provider;
    }
}
